//package com.cuijq.dubbo.common;
//
//
//import io.netty.buffer.ByteBuf;
//import io.netty.channel.ChannelHandlerContext;
//import io.netty.handler.codec.MessageToByteEncoder;
//
//import java.nio.charset.Charset;
//
//public class RpcEncoder extends MessageToByteEncoder<RpcRequest> {
//    @Override
//    protected void encode(ChannelHandlerContext ctx, RpcRequest msg, ByteBuf out) throws Exception {
//        // 简单示例，将对象转为 JSON 字符串并写入 ByteBuf
//        String json = JsonUtil.toJson(msg);
//        byte[] bytes = json.getBytes(Charset.defaultCharset());
//        out.writeInt(bytes.length);
//        out.writeBytes(bytes);
//    }
//}
